package com.gxz.job.elasticjob.start.zookeeper.annotation;

import com.dangdang.ddframe.job.lite.api.strategy.JobShardingStrategy;
import com.dangdang.ddframe.job.lite.api.strategy.impl.AverageAllocationJobShardingStrategy;

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

@Target(ElementType.TYPE) //注解定义位置
@Retention(RetentionPolicy.RUNTIME) //源码 编译 运行都有效
public @interface ElasticDataFlowJob {
    String name();
    String cron();
    int shardingTotalCount() default 1;
    boolean streamingProcess() default false;
    boolean overwrite() default false;
}